package com.zjl.Kafka.第02章_集群;

/**
 *  Kafka 的选举策略是依靠 Zookeeper ，
 * 1.刚开始 Zookeeper 没有 controller 节点
 * 2.第一个连接上 Zookeeper 的 Kafka 会创建 /controller 临时节点
 *      并 监听 /brokers/ids 节点  是为了当有其他 Kafka 来的时候 访问并告诉他，谁是主节点（老大）
 * 3.其他连接上的 Kafka 会监听 /controller 节点 就是从节点
 *      并注册 /brokers/ids/自己的broker.id的值 （这时候主节点就会监听到，主节点就会与所有其他节点（非主节点 ）发送数据）
 * 4.当 第一个 连接上 Zookeeper 的 Kafka  挂了后，临时节点就会延迟删除
 *              手动删除也行，其他Kafka 会监听到 节点的变化，就会抢占
 * 5.监听 /controller 节点变化消失后，就会抢占/controller节点，谁抢到就是主节点
 *
 * ------------------------------------------------------------------------
 * 其中 /brokers/ids/数字    #broker.id=0 这个数字
 *      每个数字都对应值broker.id这台机器的ip和端口
 * 每个 Kafka 访问 Zookeeper 时都会尝试注册 /brokers/ids/自己的broker.id的值
 *
 *
 */
public class C_kafka选举机制 {
}
